package org.groupg.project.dagdemo;

import com.lmax.disruptor.EventHandler;

public class Stage2EventHandler implements EventHandler<Stage2Event> {
    @Override
    public void onEvent(Stage2Event event, long sequence, boolean endOfBatch) {
        System.out.println("Stage 2 processing: " + event.getProcessedValue());
    }
}